/*
 ***************************************************************************************
 * All rights Reserved, Designed By RTF
 * @Title:  Constant.java   
 * @Package com.rtf.repair.mq.common
 * @Description: 消息公共常量   
 * @author: sfl
 * @date:   2020-10-20 16:17:31   
 * @version V1.0 
 * @Copyright: 2020 FOSONG. All rights reserved. 
 * 注意：本内容仅限于公司内部使用，禁止外泄以及用于其他的商业目
 *  ---------------------------------------------------------------------------------- 
 * 文件修改记录
 *     文件版本：         修改人：             修改原因：
 ***************************************************************************************
 */
package com.rtf.framework.mq.common;

/**
 *  
 *
 * @ClassName:  Constant
 * @author: sfl
 * @date:   2020-10-20 16:17:31
 * @since:  v1.0
 */
public class CommonConstants {

	/** MQ类型 kafka */
	public static final String MQ_TYPE_KAFKA = "kafka";

	/** MQ类型 rocketmq */
	public static final String MQ_TYPE_ROCKETMQ = "rocket";

	/** 消费位置最新位置，如果没有消费过无位点抛异常，只针对kafka */
	public static final int CONSUMER_OFFSET_none = -1;

	/** 消费位置从最新开始 */
	public static final int CONSUMER_OFFSET_LAST = 0;

	/** 消费位置从第一开始 */
	public static final int CONSUMER_OFFSET_FIRST = 1;

	/** 消费位置根据时间定 */
	public static final int CONSUMER_OFFSET_TIMESTAMP = 2;

}
